package com.example.mq.common;

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

//函数式接口：使用lambda表达式的前提

/**
 * 消费者接收到消息之后要调用的方法（消费信息）
 */
@FunctionalInterface
public interface Consumer {
    //deliver是“投递”的意思，这个方法意在每次服务器接收到信息后，
    // 都把消息交给消费者进行消费
    //这里的参数也是参考RabbitMQ来搞的
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
